req.setPriority(QNetworkRequest::LowPriority); // Long uploads must not block non-propagation jobs.
+ auto requestID = QByteArray{};
+
if (_url.isValid()) {
- sendRequest("PUT", _url, req, _device);
+ const auto reply = sendRequest("PUT", _url, req, _device);
+ requestID = reply->request().rawHeader("X-Request-ID");
} else {
- sendRequest("PUT", makeDavUrl(path()), req, _device);
+ const auto reply = sendRequest("PUT", makeDavUrl(path()), req, _device);
+ requestID = reply->request().rawHeader("X-Request-ID");
}
if (reply()->error() != QNetworkReply::NoError) {
qCWarning(lcPutJob) << " Network error: " << reply()->errorString();
}
+ connect(reply(), &QNetworkReply::uploadProgress, this, [requestID] (qint64 bytesSent, qint64 bytesTotal) {
+ qCDebug(lcPutJob()) << requestID << "upload progress" << bytesSent << bytesTotal;
+ });
+
connect(reply(), &QNetworkReply::uploadProgress, this, &PUTFileJob::uploadProgress);
connect(this, &AbstractNetworkJob::networkActivity, account().data(), &Account::propagatorNetworkActivity);
+
_requestTimer.start();
AbstractNetworkJob::start();
}
_body.append(onePart);
}
- sendRequest("POST", _url, req, &_body);
+ const auto newReply = sendRequest("POST", _url, req, &_body);
+ const auto &requestID = newReply->request().rawHeader("X-Request-ID");
if (reply()->error() != QNetworkReply::NoError) {
qCWarning(lcPutMultiFileJob) << " Network error: " << reply()->errorString();
}
connect(reply(), &QNetworkReply::uploadProgress, this, &PutMultiFileJob::uploadProgress);
- connect(reply(), &QNetworkReply::uploadProgress, this, [] (qint64 bytesSent, qint64 bytesTotal) {
- qCDebug(lcPutMultiFileJob()) << "upload progress" << bytesSent << bytesTotal;
- });
- connect(reply(), &QNetworkReply::bytesWritten, this, [] (qint64 bytesSent) {
- qCDebug(lcPutMultiFileJob()) << "upload progress" << bytesSent;
- });
- connect(reply(), &QNetworkReply::requestSent, this, [] () {
- qCDebug(lcPutMultiFileJob()) << "request sent";
+ connect(reply(), &QNetworkReply::uploadProgress, this, [requestID] (qint64 bytesSent, qint64 bytesTotal) {
+ qCDebug(lcPutMultiFileJob()) << requestID << "upload progress" << bytesSent << bytesTotal;
});
connect(this, &AbstractNetworkJob::networkActivity, account().data(), &Account::propagatorNetworkActivity);
_requestTimer.start();